#include "mqtt.h"
#include <unistd.h>



int main()
{
    int fd;
    while(1)
    {
        fd = mqtt_connect_server("172.31.183.197",1883);    
        if(fd < 0)
        {
            printf("MQTT连接服务器失败\n");
        } 
        sleep(1);
        break;
    }
    printf("MQTT连接服务器成功\n");

    while(1)
    {
       
        mqtt_send_heart(fd);//每隔20s发送心跳 报文
        sleep(20);
    } 

}



